package cn.doitedu.dao;

import cn.doitedu.pojo.LogBean;
import org.apache.flink.api.java.utils.ParameterTool;
import org.apache.hadoop.hbase.client.Result;

import java.util.Map;

public interface UserProfileDao {
    void init(ParameterTool parameterTool) throws Exception;

    void close() throws Exception;

    Result queryUserProfile(LogBean bean, Map<String, String> userProfiles) throws Exception;

}
